package caas

import (
	"context"
	"flow-calc/core"
	"flow-calc/core/log"
)

func ConnDemo(ctx context.Context, conn core.Connector, fn core.Function, flow core.Flow, args interface{}) error {
	log.Logger().Info("---------------------%s------------------", "ConnDemo")
	log.Logger().Info("In ConnDemo: flowName: %s, cName:%s, fnName:%s, mode:%s", flow.GetName(), conn.GetName(), fn.GetConfig().FName, fn.GetConfig().FMode)
	log.Logger().Info("Params = %+v", conn.GetConfig().Params)

	log.Logger().Info("===> Call Connector ConnDemo, args from function: %s", args)
	return nil
}
